// 引入mysql
const mysql = require('mysql');
const { DATABASE_NAME, DATABASE_USERNAME, DATABASE_PASSWORD, DATABASE_PORT, TABLE_CREATE_SUCCESS, TABLE_HISTORY_NAME } = require('../constants/constants')
// const myEmitter = require('../utils/emitterUtil');
const { saveData, getData } = require('../utils/cache')
// 创建分组表
function createHistoryTable(connection) {
    /*
      AUTO_INCREMENT 定义列为自增主键。
    */
    const sql = `
    CREATE TABLE IF NOT EXISTS ${TABLE_HISTORY_NAME} (
      id INT AUTO_INCREMENT PRIMARY KEY COMMENT '自增主键',
      lottery_id VARCHAR(255) NOT NULL COMMENT '彩票ID',
      lottery_res VARCHAR(255) NOT NULL COMMENT '开奖结果',
      lottery_no VARCHAR(255) NOT NULL COMMENT '开奖期号',
      lottery_date VARCHAR(255) NOT NULL COMMENT '开奖日期',
      lottery_exdate VARCHAR(255) NOT NULL COMMENT '兑奖截止日期',
      lottery_sale_amount VARCHAR(255) NOT NULL COMMENT '本期销售额，可能为空',
      lottery_pool_amount VARCHAR(255) NOT NULL COMMENT '奖池滚存，可能为空'
    )
  `
  console.log('准备开始创建表');
    // 执行SQL语句
    connection.query(sql, (err, result) => {
        if (err) {
            console.error('分组表创建失败:', err.message);
            return;
        }
        console.log('分组表已存在或创建');
        connection.destroy()
        saveData(TABLE_CREATE_SUCCESS,true)
        // myEmitter.emit(TABLE_CREATE_SUCCESS)
    });
}

module.exports = createHistoryTable